Flink PostgreSQL CDC配置和常见问题
Postgres的CDC源表(即Postgres的流式源表)用于依次读取PostgreSQL数据库全量快照数据和变更数据,保证不多读也不少读一条数据。即使发生故障,也能采用ExactlyOnce方式处理。idINT,PRIMARYKEY(`id`)NOTENFORCED--如果要同步的数据库表定义了
Postgres的CDC源表(即Postgres的流式源表)用于依次读取PostgreSQL数据库全量快照数据和变更数据,保证不多读也不少读一条数据。即使发生故障,也能采用ExactlyOnce方式处理。idINT,PRIMARYKEY(`id`)NOTENFORCED--如果要同步的数据库表定义了